package cn.dapeng.rpc.client;

import cn.dapeng.rpc.common.RpcResponse;

public class RPCClientStartup {

    public static void main(String[] args) {

        int threadNum = 50000;

        for (int i = 0; i < threadNum; i++) {
            final int idx = i;
            new Thread(() -> {
                String arg = "idx" + idx;
                RpcResponse response = ClientV2.call(arg);
                System.out.println("args :" + arg + " and result : " + response);
            }).start();
        }
    }

}
